import 'dart:async';

import 'package:qgchat/bloc/blocProvider.dart';
import 'package:qgchat/http/apis/user.dart';
import 'package:qgchat/http/models/addTagModel.dart';

class AllTagBloc implements BlocBase {

  void dispose(){
    _tag.close();
  }

  // ##########  STREAMS  ##############

  // 主播详情
  StreamController _tag = StreamController<List<AllTagModel>>();
  Sink get _tagSink => _tag.sink;
  Stream get tagStream => _tag.stream;
  
  // ##########  HANDLING  ##############

  void allyingxiang(int id) async {
    List<AllTagModel> result = await UserApis.allyingxiang(id);
    _tagSink.add(result);
  }
}